package cn.getech.data.development.bean

import java.io.File

import cn.getech.data.development.bean.jdbc.JDBCFieldBean
import com.alibaba.fastjson.{JSON, JSONObject}

import scala.io.Source

trait FlinkStreamJsonObj {

  def load(fileName: String): JSONObject = {
    val source = Source.fromFile(new File(fileName), "utf-8")
    val mkString = source.mkString
    source.close()
    JSON.parseObject(mkString)
  }

  def jsonParse: Unit

}
